package com.hibase.core.mq.component;

import java.util.concurrent.TimeUnit;

/**
 * 延迟队列
 * @author chenfeng
 * @version 1.0
 * @date 2021/7/23 13:46
 * @des https://gitee.com/cheershi
 */
public interface HibaseDelayQueueUtil {
    /**
     * 添加到延迟队列中
     * @param topic 队列名
     * @param msg  数据
     */
    void offer(String topic, Object msg, Long time, TimeUnit timeUnit);
}
